package com.daniel.juc.add;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;

/**
 * 同步队列
 * 没有容量
 * 进去一个元素，必须等待取出来之后，才能再往里面放一个元素
 *
 * @author Daniel
 * @version V1.0
 * @date 2020/5/21 10:09
 */
public class SynchronousQueueDemo {

	public static void main(String[] args) {
		// 同步队列
		BlockingQueue<String> blockingQueue = new SynchronousQueue<>();

		new Thread(() -> {
			try {
				blockingQueue.put("1");
				System.out.println(Thread.currentThread().getName() + " put 1");
				blockingQueue.put("2");
				System.out.println(Thread.currentThread().getName() + " put 2");
				blockingQueue.put("3");
				System.out.println(Thread.currentThread().getName() + " put 3");
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}, "T1").start();

		new Thread(() -> {
			try {
				TimeUnit.SECONDS.sleep(3);
				System.out.println(Thread.currentThread().getName() + " => " + blockingQueue.take());
				TimeUnit.SECONDS.sleep(3);
				System.out.println(Thread.currentThread().getName() + " => " + blockingQueue.take());
				TimeUnit.SECONDS.sleep(3);
				System.out.println(Thread.currentThread().getName() + " => " + blockingQueue.take());
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}, "T2").start();
	}
}
